0d650395365f5393278c7e16b4731e069108ef99,src/main/java/com/linda/framework/rpc/cluster/zk/ZkRpcClientExecutor.java,ZkRpcClientExecutor,startRpcCluster,#,264
Before Change
rpcHostAndPort.setTime(System.currentTimeMillis());
this.doUploadServerInfo(rpcHostAndPort);
//上报消费
this.doUpload();
}
@Override
After Change
//获�机器和�务列表
this.fetchRpcServers(false);
if(!isAdmin){
//上报消费者信�
RpcHostAndPort rpcHostAndPort = RpcClusterUtils.genConsumerInfo(this.getApplication(), this.getSelfIp());
this.doUploadServerInfo(rpcHostAndPort);
//上报消费
this.doUpload();
}
}